package com.citi.kafka.serializer.json;

import com.alibaba.fastjson.JSON;
import org.apache.kafka.common.serialization.Serializer;

import java.util.Map;

public class PersonJsonSerializer implements Serializer<Person> {
    public void configure(Map<String, ?> map, boolean b) {

    }

    public byte[] serialize(String topic, Person person) {
        return JSON.toJSONBytes(person);
    }

    public void close() {

    }
}
